package com.example.kafka.controller;

import com.example.kafka.service.RetriesLeakService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

/**
 * 关键业务 retries=0 Controller
 */
@RestController
public class RetriesLeakController {
    @Autowired
    private RetriesLeakService service;

    @PostMapping("/sendNoRetry")
    public String send1(@RequestBody String msg) {
        service.send1(msg);
        return "ok";
    }

    @PostMapping("/sendInfiniteRetry")
    public String send2(@RequestBody String msg) {
        service.send2(msg);
        return "ok";
    }

    @PostMapping("/sendRetryLowTimeout")
    public String send3(@RequestBody String msg) {
        service.send3(msg);
        return "ok";
    }

    @PostMapping("/sendBlindRetry")
    public String send4(@RequestBody String msg) {
        service.send4(msg);
        return "ok";
    }

    @PostMapping("/sendNoDeliveryTimeout")
    public String send5(@RequestBody String msg) {
        service.send5(msg);
        return "ok";
    }
}
